package com.psbc.mq;

import org.springframework.stereotype.Component;

/**
 * @author:y022 13/06/2022 21:13
 * @description:
 */
@Component
public class MQListener {

    /**
     * 开启消息消费确认手动模式
     *
     * @param message
     * @param channel
     */
//    @RabbitHandler
//    @RabbitListener(queuesToDeclare = @Queue("hello"))
//    public void process(Message message, Channel channel) {
//        try {
//            byte[] body = message.getBody();
//            System.out.println("message:" + new String(body));
//            //消息的offset，是否批量拒绝
//            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
//        } catch (Exception e) {
//            try {
//                //消息的offset，是否批量拒绝，消息是否重回队列
//                channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
//            } catch (IOException ioException) {
//                System.out.println(ioException);
//            }
//        }
//    }
}
